package com.atguigu.ssyx;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @作者:胡树苑
 * @时间:2025/9/21 19:37
 */
//**\- supplyAsync可以支持返回值。**
public class CompletableFutureDemo2 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //创建线程池
        ExecutorService executorService = Executors.newFixedThreadPool(3);
        System.out.println("main begin");
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("当前线程:" + Thread.currentThread().getName());
            int value =1024;
            System.out.println("value:" + value);
            return value;
        }, executorService);
        Integer value = future.get();
        System.out.println("main end:"+value);
    }

}
